/**
 * 抖音关注：程序员三丙
 * 知识星球：https://t.zsxq.com/j9b21
 */
package sanbing.example.dylike.infrastructure.queue.rpc;

import com.google.common.util.concurrent.ListenableFuture;
import sanbing.example.dylike.infrastructure.queue.QueueMsg;
import sanbing.example.dylike.util.MessagesStats;

public interface QueueRequestTemplate {

    void init();

    ListenableFuture<QueueMsg> send(QueueMsg request);

    ListenableFuture<QueueMsg> send(QueueMsg request, long timeoutNs);

    void stop();

    void setMessagesStats(MessagesStats messagesStats);
}
